package cn.iocoder.yudao.module.gpt.service.mq;

import cn.iocoder.yudao.framework.mq.core.bus.AbstractBusProducer;
import org.springframework.cloud.stream.function.StreamBridge;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Component
public class ResponseMQSender extends AbstractBusProducer{

    @Resource
    private StreamBridge streamBridge;
    public ResponseMQSender(){
        System.out.println();
    }
    public void sendFluxResponse(String dest, Object data) {
        streamBridge.send(dest,data);
    }
}
